package com.sh.data.engine.domain.integration.online.model;

public class FlinkConstant {
    /**
     * 执行flink sql的engine-flink-task-client会使用mysql语法解析器来分析输入的flinksql<br>
     * hive的flink sql中通不过它的,要使用标志来包裹相应的部分来跳过
     */
    public static final String ENGINE_FLINK_SQL_ESCAPE = "_ENGINE_FLINK_SQL_ESCAPE_";
}
